package com.mojo.webflux.reactor;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

/**
 * <pre>
 * 1、函数式编程通过Reactor框架实现，Reactor框架遵循Reactive规范
 * 2、Reactor中有两个重要接口，Mono和Flux，两者的顶级接口都是Publisher
 * 3、Mono和Flux都有三种信号（元素，错误信号，完成信号），同时具有丰富的操作符，其中主要的是map和flatMap;
 *  3.1 map是元素装换成另一种元素
 *  3.2 flatMap是将元素装换成流
 *
 * </pre>
 *
 * @author <a href="mailto:mojo_jj@163.com">Mojo</a>
 */
public class ReactorDemo {
    public static void main(String[] args) {
        //发布者创建指定项
        Mono.just(1).subscribe(System.out::print);
        Flux.just(1, 2, 3).subscribe(System.out::print);

    }
}
